<?php
//订阅 的使用 
echo '<pre>';
set_time_limit(0);
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;



// $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
// $channel = $connection->channel();
// $channel->exchange_declare('logs','fanout',false,false,false);

// $data['dfs'] = "dsfsf";
// $data =json_encode($data);
// $msg = new AMQPMessage($data);
// $channel->basic_publish($msg,'logs');


// echo "end \n"; 
// $channel->close();
// $connection->close();



date_default_timezone_set('PRC');
include_once("./excel/excel.php");
include_once("./Db_pdo.class.php");
// //添加 刷手页面

$DB=new Db_pdo("test","root","root");



// $s = new excel();
// $data = $s->dtext("./area.xlsx"); 
// foreach ($data as $key => $value) {
// 	if($value['0']){
// 		$arr[]= $value;
// 	}
// }


// echo '<pre>';
// print_r($data);

// $arr = array_chunk($data, 40000);
// foreach($arr as $v) {
// 	$sql = "INSERT INTO area (`name`,`code`,`level`,`p_name`,`p_code`) VALUES ";
// 	foreach ($v as $value) { 
		

// 		$param['name'] =$value['1'];
// 		$param['code'] = $value['2'];
// 		$param['level'] =$value['3'];
// 		$param['p_name'] =$value['4'];
// 		$param['p_code'] = $value['5'];
		
// 		// $s.='(null,3,'.$value['id'].','.$value['need_back'].',0,0,'.$value['user_id'].','.$value['back_time'].'),';
// 		// echo $s;
// 	    $values="('".implode("','",array_values($param))."'),";
// 	    // echo $values;
// 	    $sql .= $values;
// 	}
// 	$sql = rtrim($sql, ",");
// 	$DB->db->query($sql);
// 	// return ;
// }